All files / src/app/api/sort-results/[id]/shares/[sid] route.ts

95.45% Statements 42/44
100% Branches 16/16
100% Functions 3/3
95.12% Lines 39/41

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77                      3x 3x 3x 3x 3x 3x 2x 2x 1x   1x                   5x 5x 5x 5x 4x 4x 4x 3x 3x 3x 1x   2x 2x 1x   1x   1x               4x 4x 4x 4x 4x 4x 3x 3x 3x 1x   2x 1x   1x          
import { NextRequest, NextResponse } from "next/server";
import { requireAuth } from "@/lib/auth";
import { ShareController } from "@/server/api/shares";
import { getDb } from "@/lib/db";
import { requireApiResultAccess } from "@/server/dal/collection-access";
import { errorResponse } from "@/server/api/http-errors";
 
export async function GET(
  _request: NextRequest,
  { params }: { params: Promise<{ id: string; sid: string }> }
) {
  try {
    const { id, sid } = await params;
    const user = await requireAuth();
    const db = getDb();
    const access = await requireApiResultAccess(db, id, user.id);
    if (access instanceof NextResponse) return access;
    const share = await ShareController.fromDb(db).getByIdForResult(sid, id);
    if (!share) {
      return NextResponse.json({ error: "Not found" }, { status: 404 });
    }
    return NextResponse.json(share);
  } catch (error) {
    return errorResponse(error);
  }
}
 
export async function PATCH(
  request: NextRequest,
  { params }: { params: Promise<{ id: string; sid: string }> }
) {
  try {
    const { id, sid } = await params;
    const user = await requireAuth();
    const body = await request.json();
    const db = getDb();
    const access = await requireApiResultAccess(db, id, user.id);
    if (access instanceof NextResponse) return access;
    const ctrl = ShareController.fromDb(db);
    const existing = await ctrl.getByIdForResult(sid, id);
    if (!existing) {
      return NextResponse.json({ error: "Not found" }, { status: 404 });
    }
    const share = await ctrl.updateShare(sid, body);
    if (!share) {
      return NextResponse.json({ error: "Not found" }, { status: 404 });
    }
    return NextResponse.json(share);
  } catch (error) {
    return errorResponse(error);
  }
}
 
export async function DELETE(
  _request: NextRequest,
  { params }: { params: Promise<{ id: string; sid: string }> }
) {
  try {
    const { id, sid } = await params;
    const user = await requireAuth();
    const db = getDb();
    const access = await requireApiResultAccess(db, id, user.id);
    if (access instanceof NextResponse) return access;
    const ctrl = ShareController.fromDb(db);
    const existing = await ctrl.getByIdForResult(sid, id);
    if (!existing) {
      return NextResponse.json({ error: "Not found" }, { status: 404 });
    }
    if (!(await ctrl.revokeShare(sid))) {
      return NextResponse.json({ error: "Not found" }, { status: 404 });
    }
    return NextResponse.json({ message: "Share revoked" });
  } catch (error) {
    return errorResponse(error);
  }
}